3f6cd467362761195353164484ba3551c23d6cd5,modules/elasticsearch/src/main/java/org/elasticsearch/transport/netty/NettyTransport.java,NettyTransport,doStart,#,168

Before Change



    @Override protected void doStart() throws ElasticSearchException {
        clientBootstrap = new ClientBootstrap(new NioClientSocketChannelFactory(
                Executors.newCachedThreadPool(daemonThreadFactory(settings, "transportClientBoss")),
                Executors.newCachedThreadPool(daemonThreadFactory(settings, "transportClientIoWorker")),
                workerCount));
        ChannelPipelineFactory clientPipelineFactory = new ChannelPipelineFactory() {

After Change


        }

        serverOpenChannels = new OpenChannelsHandler();
        if (blockingServer) {
            serverBootstrap = new ServerBootstrap(new OioServerSocketChannelFactory(
                    Executors.newCachedThreadPool(daemonThreadFactory(settings, "transport_server_boss")),
                    Executors.newCachedThreadPool(daemonThreadFactory(settings, "transport_server_worker"))
            ));
        } else {
            serverBootstrap = new ServerBootstrap(new NioServerSocketChannelFactory(
                    Executors.newCachedThreadPool(daemonThreadFactory(settings, "transport_server_boss")),
                    Executors.newCachedThreadPool(daemonThreadFactory(settings, "transport_server_worker")),
                    workerCount));
        }